Skip to content

Conversation

CollinValley
Copy link

This follows, pretty closely, the pattern used to create Map. The new function spawns a ton of tasks to process each value from the input stream, which are then collected into a channel. Values are pulled from the channel and output via poll_next. The only substantive difference between this and Map is that the provided closure must return a future that yields an Option, rather than a T.

@CollinValley CollinValley mentioned this pull request Mar 22, 2020
79 tasks
Simple fixup with Cargo Fmt, so the tests pass.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant